package org.apache.activemq.jms.pool;

import javax.jms.TemporaryQueue;
import javax.jms.TemporaryTopic;

import com.boarsoft.message.activemq.AmqClient;

public class AmqSessionListener implements PooledSessionEventListener {
	protected AmqClient client;

	@Override
	public void onTemporaryQueueCreate(TemporaryQueue tempQueue) {
		// log.info("Temporary queue {} be createed", tempQueue.getQueueName());
	}

	@Override
	public void onTemporaryTopicCreate(TemporaryTopic tempTopic) {
		// log.info("Temporary topic {} be createed", tempTopic.getTopicName());
	}

	@Override
	public void onSessionClosed(PooledSession session) {
		client.onSessionClosed(session);
	}

	public void setClient(AmqClient client) {
		this.client = client;
	}

	public AmqClient getClient() {
		return client;
	}
}
